package com.cxl.mapreduce._16friends;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;

/**
 * @author joyson
 * @create 2019-07-09-下午8:26
 */
public class OneShareFriendsDriver {
    /**
     * 需求：以下是博客的好友列表数据，冒号前是一个用户，冒号后是该用户的所有好友（数据中的好友关系是单向的）
     * 求出哪些人两两之间有共同好友，及他俩的共同好友都有谁？
     * 数据输入
         * A:B,C,D,F,E,O
         * B:A,C,E,K
         * C:F,A,D,I
         * D:A,E,F,L
         * E:B,C,D,M,L
         * F:A,B,C,D,E,O,M
         * G:A,C,D,E,F
         * H:A,C,D,E,O
         * I:A,O
         * J:B,O
         * K:A,C,D
         * L:D,E,F
         * M:E,F,G
         * O:A,H,I,J
     * 第一次输出结果：
         * A	I,K,C,B,G,F,H,O,D,
         * B	A,F,J,E,
         * C	A,E,B,H,F,G,K,
         * D	G,C,K,A,L,F,E,H,
         * E	G,M,L,H,A,F,B,D,
         * F	L,M,D,C,G,A,s
         * G	M,
         * H	O,
         * I	O,C,
         * J	O,
         * K	B,
         * L	D,E,
         * M	E,F,
         * O	A,H,I,J,F,
     * 第二次输出结果：
         * A-B	E C
         * A-C	D F
         * A-D	E F
         * A-E	D B C
         * A-F	O B C D E
         * A-G	F E C D
         * A-H	E C D O
         * A-I	O
         * A-J	O B
         * A-K	D C
         * A-L	F E D
         * A-M	E F
         * B-C	A
         * B-D	A E
         * B-E	C
         * B-F	E A C
         * B-G	C E A
         * B-H	A E C
         * B-I	A
         * B-K	C A
         * B-L	E
         * B-M	E
         * B-O	A
         * C-D	A F
         * C-E	D
         * C-F	D A
         * C-G	D F A
         * C-H	D A
         * C-I	A
         * C-K	A D
         * C-L	D F
         * C-M	F
         * C-O	I A
         * D-E	L
         * D-F	A E
         * D-G	E A F
         * D-H	A E
         * D-I	A
         * D-K	A
         * D-L	E F
         * D-M	F E
         * D-O	A
         * E-F	D M C B
         * E-G	C D
         * E-H	C D
         * E-J	B
         * E-K	C D
         * E-L	D
         * F-G	D C A E
         * F-H	A D O E C
         * F-I	O A
         * F-J	B O
         * F-K	D C A
         * F-L	E D
         * F-M	E
         * F-O	A
         * G-H	D C E A
         * G-I	A
         * G-K	D A C
         * G-L	D F E
         * G-M	E F
         * G-O	A
         * H-I	O A
         * H-J	O
         * H-K	A C D
         * H-L	D E
         * H-M	E
         * H-O	A
         * I-J	O
         * I-K	A
         * I-O	A
         * K-L	D
         * K-O	A
         * L-M	E F
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
        args = new String[] { "/Users/a123/devWorkspace/bigData/hdfs/src/main/resources/input/friends.txt",
                "/Users/a123/devWorkspace/bigData/hdfs/src/main/resources/output/friend-step1" };
        // 1 获取job对象
        Configuration configuration = new Configuration();
        Job job = Job.getInstance(configuration);

        // 2 指定jar包运行的路径
        job.setJarByClass(OneShareFriendsDriver.class);

        // 3 指定map/reduce使用的类
        job.setMapperClass(OneShareFriendsMapper.class);
        job.setReducerClass(OneShareFriendsReducer.class);

        // 4 指定map输出的数据类型
        job.setMapOutputKeyClass(Text.class);
        job.setMapOutputValueClass(Text.class);

        // 5 指定最终输出的数据类型
        job.setOutputKeyClass(Text.class);
        job.setOutputValueClass(Text.class);

        // 6 指定job的输入原始所在目录
        FileInputFormat.setInputPaths(job, new Path(args[0]));
        FileOutputFormat.setOutputPath(job, new Path(args[1]));

        // 7 提交
        boolean result = job.waitForCompletion(true);

        System.exit(result ? 0 : 1);
    }
}
